--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
meshchatx/src/backend/rnsh_manager.py v4.7.0-rc.1 (0ac8fb19) Text, 18.67 KB
T8b949e# SPDX-License-Identifier: 0BSD
T8b949e"""RNSh session manager for MeshChatX.
Tracks multiple rnsh subprocess sessions, keeps them running in the background
while the app is active, and persists session definitions plus output history.
"""
Tff7b72from T7ee787__future__ Tff7b72import Te6edf3annotations
Tff7b72import T7ee787contextlib
Tff7b72import T7ee787json
Tff7b72import T7ee787os
Tff7b72import T7ee787shlex
Tff7b72import T7ee787shutil
Tff7b72import T7ee787subprocess
Tff7b72import T7ee787sys
Tff7b72import T7ee787threading
Tff7b72import T7ee787time
Tff7b72import T7ee787uuid
Tff7b72from T7ee787collections Tff7b72import Te6edf3deque
Tff7b72class T56d364RNSHSessionTb4b4b4:
T8b949e"""Runtime state for a single rnsh session."""
Te6edf3STATUS_STOPPED Tff7b72= Ta5d6ff"Ta5d6ffstoppedTa5d6ff"
Te6edf3STATUS_RUNNING Tff7b72= Ta5d6ff"Ta5d6ffrunningTa5d6ff"
Te6edf3STATUS_FAILED Tff7b72= Ta5d6ff"Ta5d6fffailedTa5d6ff"
Tff7b72def Tff7b72__init__Tb4b4b4(Tff7b72selfTb4b4b4, Te6edf3managerTb4b4b4, Te6edf3session_idTb4b4b4, Te6edf3configTb4b4b4)Tb4b4b4:
Tff7b72selfTff7b72.Td2a8ffmanager Tff7b72= Te6edf3manager
Tff7b72selfTff7b72.Td2a8ffsession_id Tff7b72= Te6edf3session_id
Tff7b72selfTff7b72.Td2a8ffconfig Tff7b72= Tffa657dictTb4b4b4(Te6edf3config Tff7b72or Tb4b4b4{Tb4b4b4}Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffcreated_at Tff7b72= Tffa657floatTb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffcreated_atTa5d6ff"Tb4b4b4) Tff7b72or Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffupdated_at Tff7b72= Tffa657floatTb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffupdated_atTa5d6ff"Tb4b4b4) Tff7b72or Tff7b72selfTff7b72.Td2a8ffcreated_atTb4b4b4)
Tff7b72selfTff7b72.Td2a8ffstatus Tff7b72= Tffa657strTb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffstatusTa5d6ff"Tb4b4b4) Tff7b72or Tff7b72selfTff7b72.Td2a8ffSTATUS_STOPPEDTb4b4b4)
Tff7b72selfTff7b72.Td2a8ffpid Tff7b72= Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffpidTa5d6ff"Tb4b4b4)
Tff7b72selfTff7b72.Td2a8fflast_exit_code Tff7b72= Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6fflast_exit_codeTa5d6ff"Tb4b4b4)
Tff7b72selfTff7b72.Td2a8fflast_error Tff7b72= Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6fflast_errorTa5d6ff"Tb4b4b4)
Tff7b72selfTff7b72.Td2a8fflast_command Tff7b72= Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6fflast_commandTa5d6ff"Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ff_process Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ff_stop_requested Tff7b72= Tff7b72False
Tff7b72selfTff7b72.Td2a8ff_output_seq Tff7b72= Tffa657intTb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffoutput_seqTa5d6ff"Tb4b4b4) Tff7b72or T79c0ff0Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ff_output_chunks Tff7b72= Te6edf3dequeTb4b4b4(Te6edf3maxlenTff7b72=T79c0ff4000Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ff_output_text Tff7b72= Ta5d6ff"Ta5d6ff"
Tff7b72selfTff7b72.Td2a8ff_lock Tff7b72= Te6edf3threadingTff7b72.Td2a8ffRLockTb4b4b4(Tb4b4b4)
Te6edf3saved_output Tff7b72= Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffoutput_chunksTa5d6ff"Tb4b4b4)
Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3saved_outputTb4b4b4, Tffa657listTb4b4b4)Tb4b4b4:
Tff7b72for Te6edf3item Tff7b72in Te6edf3saved_outputTb4b4b4:
Tff7b72if Tff7b72not Tffa657isinstanceTb4b4b4(Te6edf3itemTb4b4b4, Tffa657dictTb4b4b4)Tb4b4b4:
Tff7b72continue
Te6edf3seq Tff7b72= Te6edf3itemTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffseqTa5d6ff"Tb4b4b4)
Te6edf3text Tff7b72= Te6edf3itemTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6fftextTa5d6ff"Tb4b4b4)
Te6edf3ts Tff7b72= Te6edf3itemTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6fftsTa5d6ff"Tb4b4b4)
Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3seqTb4b4b4, Tffa657intTb4b4b4) Tff7b72and Tffa657isinstanceTb4b4b4(Te6edf3textTb4b4b4, Tffa657strTb4b4b4)Tb4b4b4:
Tff7b72selfTff7b72.Td2a8ff_output_chunksTff7b72.Td2a8ffappendTb4b4b4(
Tb4b4b4{
Ta5d6ff"Ta5d6ffseqTa5d6ff"Tb4b4b4: Te6edf3seqTb4b4b4,
Ta5d6ff"Ta5d6fftextTa5d6ff"Tb4b4b4: Te6edf3textTb4b4b4,
Ta5d6ff"Ta5d6fftsTa5d6ff"Tb4b4b4: Tffa657floatTb4b4b4(Te6edf3tsTb4b4b4)
Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3tsTb4b4b4, Tb4b4b4(Tffa657intTb4b4b4, Tffa657floatTb4b4b4)Tb4b4b4)
Tff7b72else Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)Tb4b4b4,
Tb4b4b4}Tb4b4b4,
Tb4b4b4)
Tff7b72if Tff7b72selfTff7b72.Td2a8ff_output_chunksTb4b4b4:
Tff7b72selfTff7b72.Td2a8ff_output_seq Tff7b72= Tffa657maxTb4b4b4(Tff7b72selfTff7b72.Td2a8ff_output_seqTb4b4b4, Tff7b72selfTff7b72.Td2a8ff_output_chunksTb4b4b4[Tff7b72-T79c0ff1Tb4b4b4]Tb4b4b4[Ta5d6ff"Ta5d6ffseqTa5d6ff"Tb4b4b4]Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ff_output_text Tff7b72= Ta5d6ff"Ta5d6ff"Tff7b72.Td2a8ffjoinTb4b4b4(
Te6edf3chunkTb4b4b4[Ta5d6ff"Ta5d6fftextTa5d6ff"Tb4b4b4] Tff7b72for Te6edf3chunk Tff7b72in Tff7b72selfTff7b72.Td2a8ff_output_chunks
Tb4b4b4)
Tf0883e@property
Tff7b72def Td2a8ffnameTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Te6edf3configured Tff7b72= Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffnameTa5d6ff"Tb4b4b4)
Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3configuredTb4b4b4, Tffa657strTb4b4b4) Tff7b72and Te6edf3configuredTff7b72.Td2a8ffstripTb4b4b4(Tb4b4b4)Tb4b4b4:
Tff7b72return Te6edf3configuredTff7b72.Td2a8ffstripTb4b4b4(Tb4b4b4)
Te6edf3mode Tff7b72= Tff7b72selfTff7b72.Td2a8ffmode
Tff7b72if Te6edf3mode Tff7b72== Ta5d6ff"Ta5d6fflistenTa5d6ff"Tb4b4b4:
Tff7b72return Ta5d6ff"Ta5d6ffListenerTa5d6ff"
Te6edf3destination Tff7b72= Tff7b72selfTff7b72.Td2a8ffdestination
Tff7b72if Te6edf3destinationTb4b4b4:
Tff7b72return Ta5d6fffTa5d6ff"Ta5d6ffSession Tffd700{Te6edf3destinationTb4b4b4[Tb4b4b4:T79c0ff10Tb4b4b4]Tffd700}Ta5d6ff"
Tff7b72return Ta5d6ff"Ta5d6ffSessionTa5d6ff"
Tf0883e@property
Tff7b72def Td2a8ffmodeTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Te6edf3mode Tff7b72= Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffmodeTa5d6ff"Tb4b4b4)
Tff7b72if Te6edf3mode Tff7b72== Ta5d6ff"Ta5d6fflistenTa5d6ff"Tb4b4b4:
Tff7b72return Ta5d6ff"Ta5d6fflistenTa5d6ff"
Tff7b72return Ta5d6ff"Ta5d6ffconnectTa5d6ff"
Tf0883e@property
Tff7b72def Td2a8ffdestinationTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Te6edf3value Tff7b72= Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffdestinationTa5d6ff"Tb4b4b4)
Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3valueTb4b4b4, Tffa657strTb4b4b4)Tb4b4b4:
Tff7b72return Te6edf3valueTff7b72.Td2a8ffstripTb4b4b4(Tb4b4b4)
Tff7b72return Ta5d6ff"Ta5d6ff"
Tff7b72def Td2a8ffto_dictTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3include_output_tailTff7b72=Tff7b72FalseTb4b4b4, Te6edf3output_tail_sizeTff7b72=T79c0ff120Tb4b4b4)Tb4b4b4:
Tff7b72with Tff7b72selfTff7b72.Td2a8ff_lockTb4b4b4:
Te6edf3payload Tff7b72= Tb4b4b4{
Ta5d6ff"Ta5d6ffidTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffsession_idTb4b4b4,
Ta5d6ff"Ta5d6ffnameTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffnameTb4b4b4,
Ta5d6ff"Ta5d6ffmodeTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffmodeTb4b4b4,
Ta5d6ff"Ta5d6ffdestinationTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffdestinationTb4b4b4,
Ta5d6ff"Ta5d6ffconfigTa5d6ff"Tb4b4b4: Tffa657dictTb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTb4b4b4)Tb4b4b4,
Ta5d6ff"Ta5d6ffstatusTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffstatusTb4b4b4,
Ta5d6ff"Ta5d6ffpidTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffpidTb4b4b4,
Ta5d6ff"Ta5d6fflast_exit_codeTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8fflast_exit_codeTb4b4b4,
Ta5d6ff"Ta5d6fflast_errorTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8fflast_errorTb4b4b4,
Ta5d6ff"Ta5d6fflast_commandTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8fflast_commandTb4b4b4,
Ta5d6ff"Ta5d6ffcreated_atTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffcreated_atTb4b4b4,
Ta5d6ff"Ta5d6ffupdated_atTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ffupdated_atTb4b4b4,
Ta5d6ff"Ta5d6ffoutput_seqTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ff_output_seqTb4b4b4,
Ta5d6ff"Ta5d6ffoutput_sizeTa5d6ff"Tb4b4b4: Tffa657lenTb4b4b4(Tff7b72selfTff7b72.Td2a8ff_output_chunksTb4b4b4)Tb4b4b4,
Tb4b4b4}
Tff7b72if Te6edf3include_output_tailTb4b4b4:
Te6edf3payloadTb4b4b4[Ta5d6ff"Ta5d6ffoutput_chunksTa5d6ff"Tb4b4b4] Tff7b72= Tffa657listTb4b4b4(Tff7b72selfTff7b72.Td2a8ff_output_chunksTb4b4b4)Tb4b4b4[
Tff7b72-Tffa657maxTb4b4b4(T79c0ff1Tb4b4b4, Tffa657intTb4b4b4(Te6edf3output_tail_sizeTb4b4b4)Tb4b4b4) Tb4b4b4:
Tb4b4b4]
Te6edf3payloadTb4b4b4[Ta5d6ff"Ta5d6ffoutput_textTa5d6ff"Tb4b4b4] Tff7b72= Tff7b72selfTff7b72.Td2a8ff_output_textTb4b4b4[Tff7b72-T79c0ff50000Tb4b4b4:Tb4b4b4]
Tff7b72return Te6edf3payload
Tff7b72def Td2a8ffoutput_sinceTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3cursorTb4b4b4)Tb4b4b4:
Tff7b72with Tff7b72selfTff7b72.Td2a8ff_lockTb4b4b4:
Te6edf3chunks Tff7b72= Tb4b4b4[Te6edf3chunk Tff7b72for Te6edf3chunk Tff7b72in Tff7b72selfTff7b72.Td2a8ff_output_chunks Tff7b72if Te6edf3chunkTb4b4b4[Ta5d6ff"Ta5d6ffseqTa5d6ff"Tb4b4b4] Tff7b72> Te6edf3cursorTb4b4b4]
Tff7b72return Tb4b4b4{
Ta5d6ff"Ta5d6ffchunksTa5d6ff"Tb4b4b4: Te6edf3chunksTb4b4b4,
Ta5d6ff"Ta5d6ffnext_cursorTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ff_output_seqTb4b4b4,
Tb4b4b4}
Tff7b72def Td2a8ffclear_outputTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Tff7b72with Tff7b72selfTff7b72.Td2a8ff_lockTb4b4b4:
Tff7b72selfTff7b72.Td2a8ff_output_chunksTff7b72.Td2a8ffclearTb4b4b4(Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ff_output_text Tff7b72= Ta5d6ff"Ta5d6ff"
Tff7b72selfTff7b72.Td2a8ffupdated_at Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffmanagerTff7b72.Td2a8ff_on_session_changeTb4b4b4(Tff7b72selfTb4b4b4)
Tff7b72selfTff7b72.Td2a8ffmanagerTff7b72.Td2a8ffsaveTb4b4b4(Tb4b4b4)
Tff7b72def Td2a8ffappend_outputTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3textTb4b4b4)Tb4b4b4:
Tff7b72if Tff7b72not Tffa657isinstanceTb4b4b4(Te6edf3textTb4b4b4, Tffa657strTb4b4b4) Tff7b72or Tff7b72not Te6edf3textTb4b4b4:
Tff7b72return Tff7b72None
Tff7b72with Tff7b72selfTff7b72.Td2a8ff_lockTb4b4b4:
Tff7b72selfTff7b72.Td2a8ff_output_seq Tff7b72+Tff7b72= T79c0ff1
Te6edf3chunk Tff7b72= Tb4b4b4{
Ta5d6ff"Ta5d6ffseqTa5d6ff"Tb4b4b4: Tff7b72selfTff7b72.Td2a8ff_output_seqTb4b4b4,
Ta5d6ff"Ta5d6fftextTa5d6ff"Tb4b4b4: Te6edf3textTb4b4b4,
Ta5d6ff"Ta5d6fftsTa5d6ff"Tb4b4b4: Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)Tb4b4b4,
Tb4b4b4}
Tff7b72selfTff7b72.Td2a8ff_output_chunksTff7b72.Td2a8ffappendTb4b4b4(Te6edf3chunkTb4b4b4)
Tff7b72selfTff7b72.Td2a8ff_output_text Tff7b72+Tff7b72= Te6edf3text
Tff7b72if Tffa657lenTb4b4b4(Tff7b72selfTff7b72.Td2a8ff_output_textTb4b4b4) Tff7b72> T79c0ff200000Tb4b4b4:
Tff7b72selfTff7b72.Td2a8ff_output_text Tff7b72= Tff7b72selfTff7b72.Td2a8ff_output_textTb4b4b4[Tff7b72-T79c0ff200000Tb4b4b4:Tb4b4b4]
Tff7b72selfTff7b72.Td2a8ffupdated_at Tff7b72= Te6edf3chunkTb4b4b4[Ta5d6ff"Ta5d6fftsTa5d6ff"Tb4b4b4]
Tff7b72return Te6edf3chunk
Tff7b72def Td2a8ff_build_commandTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Te6edf3executable Tff7b72= Te6edf3shutilTff7b72.Td2a8ffwhichTb4b4b4(Ta5d6ff"Ta5d6ffrnshTa5d6ff"Tb4b4b4)
Tff7b72if Te6edf3executableTb4b4b4:
Te6edf3command Tff7b72= Tb4b4b4[Te6edf3executableTb4b4b4]
Tff7b72elseTb4b4b4:
Te6edf3command Tff7b72= Tb4b4b4[Te6edf3sysTff7b72.Td2a8ffexecutableTb4b4b4, Ta5d6ff"Ta5d6ff-mTa5d6ff"Tb4b4b4, Ta5d6ff"Ta5d6ffRNS.Utilities.rnshTa5d6ff"Tb4b4b4]
Te6edf3config_path Tff7b72= Tb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffconfig_pathTa5d6ff"Tb4b4b4) Tff7b72or Ta5d6ff"Ta5d6ff"Tb4b4b4)Tff7b72.Td2a8ffstripTb4b4b4(Tb4b4b4)
Tff7b72if Te6edf3config_pathTb4b4b4:
Te6edf3commandTff7b72.Td2a8ffextendTb4b4b4(Tb4b4b4[Ta5d6ff"Ta5d6ff-cTa5d6ff"Tb4b4b4, Te6edf3config_pathTb4b4b4]Tb4b4b4)
Te6edf3identity_path Tff7b72= Tb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffidentity_pathTa5d6ff"Tb4b4b4) Tff7b72or Ta5d6ff"Ta5d6ff"Tb4b4b4)Tff7b72.Td2a8ffstripTb4b4b4(Tb4b4b4)
Tff7b72if Te6edf3identity_pathTb4b4b4:
Te6edf3commandTff7b72.Td2a8ffextendTb4b4b4(Tb4b4b4[Ta5d6ff"Ta5d6ff-iTa5d6ff"Tb4b4b4, Te6edf3identity_pathTb4b4b4]Tb4b4b4)
Te6edf3verbose Tff7b72= Tffa657intTb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffverboseTa5d6ff"Tb4b4b4) Tff7b72or T79c0ff0Tb4b4b4)
Te6edf3quiet Tff7b72= Tffa657intTb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffquietTa5d6ff"Tb4b4b4) Tff7b72or T79c0ff0Tb4b4b4)
Tff7b72if Te6edf3verbose Tff7b72> T79c0ff0Tb4b4b4:
Te6edf3commandTff7b72.Td2a8ffextendTb4b4b4(Tb4b4b4[Ta5d6ff"Ta5d6ff-vTa5d6ff"Tb4b4b4] Tff7b72* Tffa657minTb4b4b4(Te6edf3verboseTb4b4b4, T79c0ff3Tb4b4b4)Tb4b4b4)
Tff7b72if Te6edf3quiet Tff7b72> T79c0ff0Tb4b4b4:
Te6edf3commandTff7b72.Td2a8ffextendTb4b4b4(Tb4b4b4[Ta5d6ff"Ta5d6ff-qTa5d6ff"Tb4b4b4] Tff7b72* Tffa657minTb4b4b4(Te6edf3quietTb4b4b4, T79c0ff3Tb4b4b4)Tb4b4b4)
Tff7b72if Tffa657boolTb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffmirrorTa5d6ff"Tb4b4b4)Tb4b4b4)Tb4b4b4:
Te6edf3commandTff7b72.Td2a8ffappendTb4b4b4(Ta5d6ff"Ta5d6ff-mTa5d6ff"Tb4b4b4)
Te6edf3timeout Tff7b72= Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6fftimeoutTa5d6ff"Tb4b4b4)
Tff7b72if Te6edf3timeout Tff7b72not Tff7b72in Tb4b4b4(Tff7b72NoneTb4b4b4, Ta5d6ff"Ta5d6ff"Tb4b4b4)Tb4b4b4:
Te6edf3commandTff7b72.Td2a8ffextendTb4b4b4(Tb4b4b4[Ta5d6ff"Ta5d6ff-wTa5d6ff"Tb4b4b4, Tffa657strTb4b4b4(Te6edf3timeoutTb4b4b4)Tb4b4b4]Tb4b4b4)
Te6edf3service Tff7b72= Tb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffserviceTa5d6ff"Tb4b4b4) Tff7b72or Ta5d6ff"Ta5d6ff"Tb4b4b4)Tff7b72.Td2a8ffstripTb4b4b4(Tb4b4b4)
Tff7b72if Te6edf3serviceTb4b4b4:
Te6edf3commandTff7b72.Td2a8ffextendTb4b4b4(Tb4b4b4[Ta5d6ff"Ta5d6ff-sTa5d6ff"Tb4b4b4, Te6edf3serviceTb4b4b4]Tb4b4b4)
Te6edf3extra_args Tff7b72= Tb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffextra_argsTa5d6ff"Tb4b4b4) Tff7b72or Ta5d6ff"Ta5d6ff"Tb4b4b4)Tff7b72.Td2a8ffstripTb4b4b4(Tb4b4b4)
Tff7b72if Te6edf3extra_argsTb4b4b4:
Te6edf3commandTff7b72.Td2a8ffextendTb4b4b4(Te6edf3shlexTff7b72.Td2a8ffsplitTb4b4b4(Te6edf3extra_argsTb4b4b4)Tb4b4b4)
Te6edf3mode Tff7b72= Tff7b72selfTff7b72.Td2a8ffmode
Tff7b72if Te6edf3mode Tff7b72== Ta5d6ff"Ta5d6fflistenTa5d6ff"Tb4b4b4:
Te6edf3commandTff7b72.Td2a8ffappendTb4b4b4(Ta5d6ff"Ta5d6ff-lTa5d6ff"Tb4b4b4)
Te6edf3announce_period Tff7b72= Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffannounce_periodTa5d6ff"Tb4b4b4)
Tff7b72if Te6edf3announce_period Tff7b72not Tff7b72in Tb4b4b4(Tff7b72NoneTb4b4b4, Ta5d6ff"Ta5d6ff"Tb4b4b4)Tb4b4b4:
Te6edf3commandTff7b72.Td2a8ffextendTb4b4b4(Tb4b4b4[Ta5d6ff"Ta5d6ff-bTa5d6ff"Tb4b4b4, Tffa657strTb4b4b4(Te6edf3announce_periodTb4b4b4)Tb4b4b4]Tb4b4b4)
Te6edf3allowed_hashes Tff7b72= Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffallowed_hashesTa5d6ff"Tb4b4b4)
Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3allowed_hashesTb4b4b4, Tffa657listTb4b4b4)Tb4b4b4:
Tff7b72for Te6edf3item Tff7b72in Te6edf3allowed_hashesTb4b4b4:
Te6edf3value Tff7b72= Tffa657strTb4b4b4(Te6edf3itemTb4b4b4)Tff7b72.Td2a8ffstripTb4b4b4(Tb4b4b4)
Tff7b72if Te6edf3valueTb4b4b4:
Te6edf3commandTff7b72.Td2a8ffextendTb4b4b4(Tb4b4b4[Ta5d6ff"Ta5d6ff-aTa5d6ff"Tb4b4b4, Te6edf3valueTb4b4b4]Tb4b4b4)
Tff7b72if Tffa657boolTb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffno_authTa5d6ff"Tb4b4b4)Tb4b4b4)Tb4b4b4:
Te6edf3commandTff7b72.Td2a8ffappendTb4b4b4(Ta5d6ff"Ta5d6ff-nTa5d6ff"Tb4b4b4)
Tff7b72if Tffa657boolTb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffremote_command_as_argsTa5d6ff"Tb4b4b4)Tb4b4b4)Tb4b4b4:
Te6edf3commandTff7b72.Td2a8ffappendTb4b4b4(Ta5d6ff"Ta5d6ff-ATa5d6ff"Tb4b4b4)
Tff7b72if Tffa657boolTb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffno_remote_commandTa5d6ff"Tb4b4b4)Tb4b4b4)Tb4b4b4:
Te6edf3commandTff7b72.Td2a8ffappendTb4b4b4(Ta5d6ff"Ta5d6ff-CTa5d6ff"Tb4b4b4)
Te6edf3default_command Tff7b72= Tb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffdefault_commandTa5d6ff"Tb4b4b4) Tff7b72or Ta5d6ff"Ta5d6ff"Tb4b4b4)Tff7b72.Td2a8ffstripTb4b4b4(Tb4b4b4)
Tff7b72if Te6edf3default_commandTb4b4b4:
Te6edf3commandTff7b72.Td2a8ffappendTb4b4b4(Ta5d6ff"Ta5d6ff--Ta5d6ff"Tb4b4b4)
Te6edf3commandTff7b72.Td2a8ffextendTb4b4b4(Te6edf3shlexTff7b72.Td2a8ffsplitTb4b4b4(Te6edf3default_commandTb4b4b4)Tb4b4b4)
Tff7b72elseTb4b4b4:
Tff7b72if Tffa657boolTb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffno_idTa5d6ff"Tb4b4b4)Tb4b4b4)Tb4b4b4:
Te6edf3commandTff7b72.Td2a8ffappendTb4b4b4(Ta5d6ff"Ta5d6ff-NTa5d6ff"Tb4b4b4)
Te6edf3destination Tff7b72= Tff7b72selfTff7b72.Td2a8ffdestination
Tff7b72if Tff7b72not Te6edf3destinationTb4b4b4:
Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffDestination hash is required for connect modeTa5d6ff"Tb4b4b4)
Te6edf3commandTff7b72.Td2a8ffappendTb4b4b4(Te6edf3destinationTb4b4b4)
Te6edf3remote_command Tff7b72= Tb4b4b4(Tff7b72selfTff7b72.Td2a8ffconfigTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffremote_commandTa5d6ff"Tb4b4b4) Tff7b72or Ta5d6ff"Ta5d6ff"Tb4b4b4)Tff7b72.Td2a8ffstripTb4b4b4(Tb4b4b4)
Tff7b72if Te6edf3remote_commandTb4b4b4:
Te6edf3commandTff7b72.Td2a8ffappendTb4b4b4(Ta5d6ff"Ta5d6ff--Ta5d6ff"Tb4b4b4)
Te6edf3commandTff7b72.Td2a8ffextendTb4b4b4(Te6edf3shlexTff7b72.Td2a8ffsplitTb4b4b4(Te6edf3remote_commandTb4b4b4)Tb4b4b4)
Tff7b72return Te6edf3command
Tff7b72def Td2a8ffstartTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Tff7b72with Tff7b72selfTff7b72.Td2a8ff_lockTb4b4b4:
Tff7b72if Tff7b72selfTff7b72.Td2a8ff_process Tff7b72is Tff7b72not Tff7b72None Tff7b72and Tff7b72selfTff7b72.Td2a8ff_processTff7b72.Td2a8ffpollTb4b4b4(Tb4b4b4) Tff7b72is Tff7b72NoneTb4b4b4:
Tff7b72return Tff7b72selfTff7b72.Td2a8ffto_dictTb4b4b4(Te6edf3include_output_tailTff7b72=Tff7b72TrueTb4b4b4)
Te6edf3command Tff7b72= Tff7b72selfTff7b72.Td2a8ff_build_commandTb4b4b4(Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ff_stop_requested Tff7b72= Tff7b72False
Tff7b72selfTff7b72.Td2a8fflast_error Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8fflast_exit_code Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8fflast_command Tff7b72= Ta5d6ff"Ta5d6ff Ta5d6ff"Tff7b72.Td2a8ffjoinTb4b4b4(Te6edf3shlexTff7b72.Td2a8ffquoteTb4b4b4(Te6edf3partTb4b4b4) Tff7b72for Te6edf3part Tff7b72in Te6edf3commandTb4b4b4)
Tff7b72selfTff7b72.Td2a8ff_process Tff7b72= Te6edf3subprocessTff7b72.Td2a8ffPopenTb4b4b4( T8b949e# noqa: S603
Te6edf3commandTb4b4b4,
Te6edf3stdinTff7b72=Te6edf3subprocessTff7b72.Td2a8ffPIPETb4b4b4,
Te6edf3stdoutTff7b72=Te6edf3subprocessTff7b72.Td2a8ffPIPETb4b4b4,
Te6edf3stderrTff7b72=Te6edf3subprocessTff7b72.Td2a8ffSTDOUTTb4b4b4,
Te6edf3bufsizeTff7b72=T79c0ff0Tb4b4b4,
Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffpid Tff7b72= Tff7b72selfTff7b72.Td2a8ff_processTff7b72.Td2a8ffpid
Tff7b72selfTff7b72.Td2a8ffstatus Tff7b72= Tff7b72selfTff7b72.Td2a8ffSTATUS_RUNNING
Tff7b72selfTff7b72.Td2a8ffupdated_at Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffmanagerTff7b72.Td2a8ff_on_session_changeTb4b4b4(Tff7b72selfTb4b4b4)
Tff7b72selfTff7b72.Td2a8ffmanagerTff7b72.Td2a8ffsaveTb4b4b4(Tb4b4b4)
Te6edf3reader Tff7b72= Te6edf3threadingTff7b72.Td2a8ffThreadTb4b4b4(Te6edf3targetTff7b72=Tff7b72selfTff7b72.Td2a8ff_reader_loopTb4b4b4, Te6edf3daemonTff7b72=Tff7b72TrueTb4b4b4)
Te6edf3readerTff7b72.Td2a8ffstartTb4b4b4(Tb4b4b4)
Te6edf3waiter Tff7b72= Te6edf3threadingTff7b72.Td2a8ffThreadTb4b4b4(Te6edf3targetTff7b72=Tff7b72selfTff7b72.Td2a8ff_waiter_loopTb4b4b4, Te6edf3daemonTff7b72=Tff7b72TrueTb4b4b4)
Te6edf3waiterTff7b72.Td2a8ffstartTb4b4b4(Tb4b4b4)
Tff7b72return Tff7b72selfTff7b72.Td2a8ffto_dictTb4b4b4(Te6edf3include_output_tailTff7b72=Tff7b72TrueTb4b4b4)
Tff7b72def Td2a8ffstopTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Tff7b72with Tff7b72selfTff7b72.Td2a8ff_lockTb4b4b4:
Te6edf3process Tff7b72= Tff7b72selfTff7b72.Td2a8ff_process
Tff7b72selfTff7b72.Td2a8ff_stop_requested Tff7b72= Tff7b72True
Tff7b72if Te6edf3process Tff7b72is Tff7b72NoneTb4b4b4:
Tff7b72return Tff7b72selfTff7b72.Td2a8ffto_dictTb4b4b4(Te6edf3include_output_tailTff7b72=Tff7b72TrueTb4b4b4)
Tff7b72with Te6edf3contextlibTff7b72.Td2a8ffsuppressTb4b4b4(Tf85149ExceptionTb4b4b4)Tb4b4b4:
Te6edf3processTff7b72.Td2a8ffterminateTb4b4b4(Tb4b4b4)
Tff7b72tryTb4b4b4:
Te6edf3processTff7b72.Td2a8ffwaitTb4b4b4(Te6edf3timeoutTff7b72=T79c0ff2.5Tb4b4b4)
Tff7b72except Tf85149ExceptionTb4b4b4:
Tff7b72with Te6edf3contextlibTff7b72.Td2a8ffsuppressTb4b4b4(Tf85149ExceptionTb4b4b4)Tb4b4b4:
Te6edf3processTff7b72.Td2a8ffkillTb4b4b4(Tb4b4b4)
Tff7b72return Tff7b72selfTff7b72.Td2a8ffto_dictTb4b4b4(Te6edf3include_output_tailTff7b72=Tff7b72TrueTb4b4b4)
Tff7b72def Td2a8ffsend_inputTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3textTb4b4b4)Tb4b4b4:
Tff7b72if Tff7b72not Tffa657isinstanceTb4b4b4(Te6edf3textTb4b4b4, Tffa657strTb4b4b4)Tb4b4b4:
Tff7b72raise Tf85149ValueErrorTb4b4b4(Ta5d6ff"Ta5d6ffInput must be a stringTa5d6ff"Tb4b4b4)
Tff7b72with Tff7b72selfTff7b72.Td2a8ff_lockTb4b4b4:
Te6edf3process Tff7b72= Tff7b72selfTff7b72.Td2a8ff_process
Tff7b72if Te6edf3process Tff7b72is Tff7b72None Tff7b72or Te6edf3processTff7b72.Td2a8ffpollTb4b4b4(Tb4b4b4) Tff7b72is Tff7b72not Tff7b72NoneTb4b4b4:
Tff7b72raise Tf85149RuntimeErrorTb4b4b4(Ta5d6ff"Ta5d6ffSession is not runningTa5d6ff"Tb4b4b4)
Te6edf3stdin Tff7b72= Te6edf3processTff7b72.Td2a8ffstdin
Tff7b72if Te6edf3stdin Tff7b72is Tff7b72NoneTb4b4b4:
Tff7b72raise Tf85149RuntimeErrorTb4b4b4(Ta5d6ff"Ta5d6ffSession stdin is unavailableTa5d6ff"Tb4b4b4)
Te6edf3stdinTff7b72.Td2a8ffwriteTb4b4b4(Te6edf3textTff7b72.Td2a8ffencodeTb4b4b4(Ta5d6ff"Ta5d6ffutf-8Ta5d6ff"Tb4b4b4, Te6edf3errorsTff7b72=Ta5d6ff"Ta5d6ffreplaceTa5d6ff"Tb4b4b4)Tb4b4b4)
Te6edf3stdinTff7b72.Td2a8ffflushTb4b4b4(Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffupdated_at Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffmanagerTff7b72.Td2a8ffsaveTb4b4b4(Tb4b4b4)
Tff7b72return Tff7b72selfTff7b72.Td2a8ffto_dictTb4b4b4(Te6edf3include_output_tailTff7b72=Tff7b72FalseTb4b4b4)
Tff7b72def Td2a8ff_reader_loopTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Tff7b72while Tff7b72TrueTb4b4b4:
Tff7b72with Tff7b72selfTff7b72.Td2a8ff_lockTb4b4b4:
Te6edf3process Tff7b72= Tff7b72selfTff7b72.Td2a8ff_process
Te6edf3stdout Tff7b72= Te6edf3processTff7b72.Td2a8ffstdout Tff7b72if Te6edf3process Tff7b72is Tff7b72not Tff7b72None Tff7b72else Tff7b72None
Tff7b72if Te6edf3process Tff7b72is Tff7b72None Tff7b72or Te6edf3stdout Tff7b72is Tff7b72NoneTb4b4b4:
Tff7b72return
Tff7b72tryTb4b4b4:
Te6edf3chunk Tff7b72= Te6edf3osTff7b72.Td2a8ffreadTb4b4b4(Te6edf3stdoutTff7b72.Td2a8fffilenoTb4b4b4(Tb4b4b4)Tb4b4b4, T79c0ff4096Tb4b4b4)
Tff7b72except Tf85149ExceptionTb4b4b4:
Tff7b72return
Tff7b72if Tff7b72not Te6edf3chunkTb4b4b4:
Tff7b72return
Te6edf3text Tff7b72= Te6edf3chunkTff7b72.Td2a8ffdecodeTb4b4b4(Ta5d6ff"Ta5d6ffutf-8Ta5d6ff"Tb4b4b4, Te6edf3errorsTff7b72=Ta5d6ff"Ta5d6ffreplaceTa5d6ff"Tb4b4b4)
Te6edf3output_chunk Tff7b72= Tff7b72selfTff7b72.Td2a8ffappend_outputTb4b4b4(Te6edf3textTb4b4b4)
Tff7b72if Te6edf3output_chunk Tff7b72is Tff7b72not Tff7b72NoneTb4b4b4:
Tff7b72selfTff7b72.Td2a8ffmanagerTff7b72.Td2a8ff_on_session_outputTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3output_chunkTb4b4b4)
Tff7b72selfTff7b72.Td2a8ffmanagerTff7b72.Td2a8ffsaveTb4b4b4(Tb4b4b4)
Tff7b72def Td2a8ff_waiter_loopTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Tff7b72with Tff7b72selfTff7b72.Td2a8ff_lockTb4b4b4:
Te6edf3process Tff7b72= Tff7b72selfTff7b72.Td2a8ff_process
Tff7b72if Te6edf3process Tff7b72is Tff7b72NoneTb4b4b4:
Tff7b72return
Te6edf3exit_code Tff7b72= Te6edf3processTff7b72.Td2a8ffwaitTb4b4b4(Tb4b4b4)
Tff7b72with Tff7b72selfTff7b72.Td2a8ff_lockTb4b4b4:
Tff7b72selfTff7b72.Td2a8fflast_exit_code Tff7b72= Te6edf3exit_code
Tff7b72selfTff7b72.Td2a8ffpid Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ff_process Tff7b72= Tff7b72None
Tff7b72if Tff7b72selfTff7b72.Td2a8ff_stop_requestedTb4b4b4:
Tff7b72selfTff7b72.Td2a8ffstatus Tff7b72= Tff7b72selfTff7b72.Td2a8ffSTATUS_STOPPED
Tff7b72elseTb4b4b4:
Tff7b72selfTff7b72.Td2a8ffstatus Tff7b72= Tb4b4b4(
Tff7b72selfTff7b72.Td2a8ffSTATUS_FAILED Tff7b72if Te6edf3exit_code Tff7b72!= T79c0ff0 Tff7b72else Tff7b72selfTff7b72.Td2a8ffSTATUS_STOPPED
Tb4b4b4)
Tff7b72if Te6edf3exit_code Tff7b72!= T79c0ff0 Tff7b72and Tff7b72not Tff7b72selfTff7b72.Td2a8fflast_errorTb4b4b4:
Tff7b72selfTff7b72.Td2a8fflast_error Tff7b72= Ta5d6fffTa5d6ff"Ta5d6ffrnsh exited with code Tffd700{Te6edf3exit_codeTffd700}Ta5d6ff"
Tff7b72selfTff7b72.Td2a8ffupdated_at Tff7b72= Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffmanagerTff7b72.Td2a8ff_on_session_changeTb4b4b4(Tff7b72selfTb4b4b4)
Tff7b72selfTff7b72.Td2a8ffmanagerTff7b72.Td2a8ffsaveTb4b4b4(Tb4b4b4)
Tff7b72def Td2a8ffshutdownTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Tff7b72with Te6edf3contextlibTff7b72.Td2a8ffsuppressTb4b4b4(Tf85149ExceptionTb4b4b4)Tb4b4b4:
Tff7b72selfTff7b72.Td2a8ffstopTb4b4b4(Tb4b4b4)
Tff7b72def Td2a8ffto_storeTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Te6edf3data Tff7b72= Tff7b72selfTff7b72.Td2a8ffto_dictTb4b4b4(Te6edf3include_output_tailTff7b72=Tff7b72TrueTb4b4b4, Te6edf3output_tail_sizeTff7b72=T79c0ff400Tb4b4b4)
Te6edf3dataTb4b4b4[Ta5d6ff"Ta5d6ffcreated_atTa5d6ff"Tb4b4b4] Tff7b72= Tff7b72selfTff7b72.Td2a8ffcreated_at
Te6edf3dataTb4b4b4[Ta5d6ff"Ta5d6ffupdated_atTa5d6ff"Tb4b4b4] Tff7b72= Tff7b72selfTff7b72.Td2a8ffupdated_at
Te6edf3dataTb4b4b4[Ta5d6ff"Ta5d6ffstatusTa5d6ff"Tb4b4b4] Tff7b72= Tff7b72selfTff7b72.Td2a8ffstatus
Tff7b72return Te6edf3data
Tff7b72class T56d364RNSHManagerTb4b4b4:
T8b949e"""Manage multiple rnsh sessions and persisted state."""
Tff7b72def Tff7b72__init__Tb4b4b4(Tff7b72selfTb4b4b4, Te6edf3storage_dirTb4b4b4)Tb4b4b4:
Tff7b72selfTff7b72.Td2a8ffstorage_dir Tff7b72= Te6edf3storage_dir
Tff7b72selfTff7b72.Td2a8ff_sessions Tff7b72= Tb4b4b4{Tb4b4b4}
Tff7b72selfTff7b72.Td2a8ff_change_callback Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ff_output_callback Tff7b72= Tff7b72None
Tff7b72selfTff7b72.Td2a8ff_lock Tff7b72= Te6edf3threadingTff7b72.Td2a8ffRLockTb4b4b4(Tb4b4b4)
Tff7b72def Td2a8ffset_change_callbackTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3callbackTb4b4b4)Tb4b4b4:
Tff7b72selfTff7b72.Td2a8ff_change_callback Tff7b72= Te6edf3callback
Tff7b72def Td2a8ffset_output_callbackTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3callbackTb4b4b4)Tb4b4b4:
Tff7b72selfTff7b72.Td2a8ff_output_callback Tff7b72= Te6edf3callback
Tff7b72def Td2a8ff_store_pathTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Tff7b72return Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffjoinTb4b4b4(Tff7b72selfTff7b72.Td2a8ffstorage_dirTb4b4b4, Ta5d6ff"Ta5d6ffrnsh_sessions.jsonTa5d6ff"Tb4b4b4)
Tff7b72def Td2a8ffloadTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Te6edf3path Tff7b72= Tff7b72selfTff7b72.Td2a8ff_store_pathTb4b4b4(Tb4b4b4)
Tff7b72if Tff7b72not Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffexistsTb4b4b4(Te6edf3pathTb4b4b4)Tb4b4b4:
Tff7b72return
Tff7b72with Tffa657openTb4b4b4(Te6edf3pathTb4b4b4, Te6edf3encodingTff7b72=Ta5d6ff"Ta5d6ffutf-8Ta5d6ff"Tb4b4b4) Tff7b72as Te6edf3handleTb4b4b4:
Te6edf3data Tff7b72= Te6edf3jsonTff7b72.Td2a8ffloadTb4b4b4(Te6edf3handleTb4b4b4)
Te6edf3sessions Tff7b72= Te6edf3dataTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffsessionsTa5d6ff"Tb4b4b4)
Tff7b72if Tff7b72not Tffa657isinstanceTb4b4b4(Te6edf3sessionsTb4b4b4, Tffa657listTb4b4b4)Tb4b4b4:
Tff7b72return
Tff7b72with Tff7b72selfTff7b72.Td2a8ff_lockTb4b4b4:
Tff7b72selfTff7b72.Td2a8ff_sessions Tff7b72= Tb4b4b4{Tb4b4b4}
Tff7b72for Te6edf3item Tff7b72in Te6edf3sessionsTb4b4b4:
Tff7b72if Tff7b72not Tffa657isinstanceTb4b4b4(Te6edf3itemTb4b4b4, Tffa657dictTb4b4b4)Tb4b4b4:
Tff7b72continue
Te6edf3session_id Tff7b72= Te6edf3itemTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffidTa5d6ff"Tb4b4b4)
Tff7b72if Tff7b72not Tffa657isinstanceTb4b4b4(Te6edf3session_idTb4b4b4, Tffa657strTb4b4b4) Tff7b72or Tff7b72not Te6edf3session_idTff7b72.Td2a8ffstripTb4b4b4(Tb4b4b4)Tb4b4b4:
Tff7b72continue
Te6edf3session Tff7b72= Te6edf3RNSHSessionTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3session_idTb4b4b4, Te6edf3itemTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffconfigTa5d6ff"Tb4b4b4) Tff7b72or Te6edf3itemTb4b4b4)
Te6edf3sessionTff7b72.Td2a8ffcreated_at Tff7b72= Tffa657floatTb4b4b4(Te6edf3itemTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffcreated_atTa5d6ff"Tb4b4b4) Tff7b72or Te6edf3sessionTff7b72.Td2a8ffcreated_atTb4b4b4)
Te6edf3sessionTff7b72.Td2a8ffupdated_at Tff7b72= Tffa657floatTb4b4b4(Te6edf3itemTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffupdated_atTa5d6ff"Tb4b4b4) Tff7b72or Te6edf3sessionTff7b72.Td2a8ffupdated_atTb4b4b4)
Te6edf3sessionTff7b72.Td2a8ffstatus Tff7b72= Te6edf3RNSHSessionTff7b72.Td2a8ffSTATUS_STOPPED
Te6edf3sessionTff7b72.Td2a8ffpid Tff7b72= Tff7b72None
Te6edf3sessionTff7b72.Td2a8fflast_exit_code Tff7b72= Te6edf3itemTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6fflast_exit_codeTa5d6ff"Tb4b4b4)
Te6edf3sessionTff7b72.Td2a8fflast_error Tff7b72= Te6edf3itemTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6fflast_errorTa5d6ff"Tb4b4b4)
Te6edf3sessionTff7b72.Td2a8fflast_command Tff7b72= Te6edf3itemTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6fflast_commandTa5d6ff"Tb4b4b4)
Te6edf3sessionTff7b72.Td2a8ff_output_seq Tff7b72= Tffa657intTb4b4b4(Te6edf3itemTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffoutput_seqTa5d6ff"Tb4b4b4) Tff7b72or Te6edf3sessionTff7b72.Td2a8ff_output_seqTb4b4b4)
Te6edf3stored_chunks Tff7b72= Te6edf3itemTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffoutput_chunksTa5d6ff"Tb4b4b4)
Tff7b72if Tffa657isinstanceTb4b4b4(Te6edf3stored_chunksTb4b4b4, Tffa657listTb4b4b4)Tb4b4b4:
Te6edf3sessionTff7b72.Td2a8ff_output_chunksTff7b72.Td2a8ffclearTb4b4b4(Tb4b4b4)
Te6edf3sessionTff7b72.Td2a8ff_output_text Tff7b72= Ta5d6ff"Ta5d6ff"
Tff7b72for Te6edf3chunk Tff7b72in Te6edf3stored_chunksTb4b4b4:
Tff7b72if Tb4b4b4(
Tffa657isinstanceTb4b4b4(Te6edf3chunkTb4b4b4, Tffa657dictTb4b4b4)
Tff7b72and Tffa657isinstanceTb4b4b4(Te6edf3chunkTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffseqTa5d6ff"Tb4b4b4)Tb4b4b4, Tffa657intTb4b4b4)
Tff7b72and Tffa657isinstanceTb4b4b4(Te6edf3chunkTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6fftextTa5d6ff"Tb4b4b4)Tb4b4b4, Tffa657strTb4b4b4)
Tb4b4b4)Tb4b4b4:
Te6edf3sessionTff7b72.Td2a8ff_output_chunksTff7b72.Td2a8ffappendTb4b4b4(
Tb4b4b4{
Ta5d6ff"Ta5d6ffseqTa5d6ff"Tb4b4b4: Te6edf3chunkTb4b4b4[Ta5d6ff"Ta5d6ffseqTa5d6ff"Tb4b4b4]Tb4b4b4,
Ta5d6ff"Ta5d6fftextTa5d6ff"Tb4b4b4: Te6edf3chunkTb4b4b4[Ta5d6ff"Ta5d6fftextTa5d6ff"Tb4b4b4]Tb4b4b4,
Ta5d6ff"Ta5d6fftsTa5d6ff"Tb4b4b4: Tffa657floatTb4b4b4(Te6edf3chunkTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6fftsTa5d6ff"Tb4b4b4) Tff7b72or Te6edf3timeTff7b72.Td2a8fftimeTb4b4b4(Tb4b4b4)Tb4b4b4)Tb4b4b4,
Tb4b4b4}Tb4b4b4,
Tb4b4b4)
Te6edf3sessionTff7b72.Td2a8ff_output_text Tff7b72= Ta5d6ff"Ta5d6ff"Tff7b72.Td2a8ffjoinTb4b4b4(
Te6edf3cTb4b4b4[Ta5d6ff"Ta5d6fftextTa5d6ff"Tb4b4b4] Tff7b72for Te6edf3c Tff7b72in Te6edf3sessionTff7b72.Td2a8ff_output_chunks
Tb4b4b4)
Tff7b72if Te6edf3sessionTff7b72.Td2a8ff_output_chunksTb4b4b4:
Te6edf3sessionTff7b72.Td2a8ff_output_seq Tff7b72= Tffa657maxTb4b4b4(
Te6edf3sessionTff7b72.Td2a8ff_output_seqTb4b4b4,
Te6edf3sessionTff7b72.Td2a8ff_output_chunksTb4b4b4[Tff7b72-T79c0ff1Tb4b4b4]Tb4b4b4[Ta5d6ff"Ta5d6ffseqTa5d6ff"Tb4b4b4]Tb4b4b4,
Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ff_sessionsTb4b4b4[Te6edf3session_idTb4b4b4] Tff7b72= Te6edf3session
Tff7b72def Td2a8ffsaveTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Tff7b72with Tff7b72selfTff7b72.Td2a8ff_lockTb4b4b4:
Te6edf3payload Tff7b72= Tb4b4b4{
Ta5d6ff"Ta5d6ffsessionsTa5d6ff"Tb4b4b4: Tb4b4b4[Te6edf3sessionTff7b72.Td2a8ffto_storeTb4b4b4(Tb4b4b4) Tff7b72for Te6edf3session Tff7b72in Tff7b72selfTff7b72.Td2a8ff_sessionsTff7b72.Td2a8ffvaluesTb4b4b4(Tb4b4b4)Tb4b4b4]Tb4b4b4,
Tb4b4b4}
Te6edf3path Tff7b72= Tff7b72selfTff7b72.Td2a8ff_store_pathTb4b4b4(Tb4b4b4)
Te6edf3osTff7b72.Td2a8ffmakedirsTb4b4b4(Te6edf3osTff7b72.Td2a8ffpathTff7b72.Td2a8ffdirnameTb4b4b4(Te6edf3pathTb4b4b4)Tb4b4b4, Te6edf3exist_okTff7b72=Tff7b72TrueTb4b4b4)
Tff7b72with Tffa657openTb4b4b4(Te6edf3pathTb4b4b4, Ta5d6ff"Ta5d6ffwTa5d6ff"Tb4b4b4, Te6edf3encodingTff7b72=Ta5d6ff"Ta5d6ffutf-8Ta5d6ff"Tb4b4b4) Tff7b72as Te6edf3handleTb4b4b4:
Te6edf3jsonTff7b72.Td2a8ffdumpTb4b4b4(Te6edf3payloadTb4b4b4, Te6edf3handleTb4b4b4, Te6edf3ensure_asciiTff7b72=Tff7b72FalseTb4b4b4, Te6edf3indentTff7b72=T79c0ff2Tb4b4b4)
Tff7b72def Td2a8fflist_sessionsTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Tff7b72with Tff7b72selfTff7b72.Td2a8ff_lockTb4b4b4:
Te6edf3sessions Tff7b72= Tb4b4b4[
Te6edf3sessionTff7b72.Td2a8ffto_dictTb4b4b4(Te6edf3include_output_tailTff7b72=Tff7b72TrueTb4b4b4)
Tff7b72for Te6edf3session Tff7b72in Tff7b72selfTff7b72.Td2a8ff_sessionsTff7b72.Td2a8ffvaluesTb4b4b4(Tb4b4b4)
Tb4b4b4]
Te6edf3sessionsTff7b72.Td2a8ffsortTb4b4b4(Te6edf3keyTff7b72=Tff7b72lambda Te6edf3itemTb4b4b4: Te6edf3itemTff7b72.Td2a8ffgetTb4b4b4(Ta5d6ff"Ta5d6ffupdated_atTa5d6ff"Tb4b4b4, T79c0ff0Tb4b4b4)Tb4b4b4, Te6edf3reverseTff7b72=Tff7b72TrueTb4b4b4)
Tff7b72return Tb4b4b4{Ta5d6ff"Ta5d6ffsessionsTa5d6ff"Tb4b4b4: Te6edf3sessionsTb4b4b4}
Tff7b72def Td2a8fffind_sessionTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3session_idTb4b4b4)Tb4b4b4:
Tff7b72with Tff7b72selfTff7b72.Td2a8ff_lockTb4b4b4:
Tff7b72return Tff7b72selfTff7b72.Td2a8ff_sessionsTff7b72.Td2a8ffgetTb4b4b4(Te6edf3session_idTb4b4b4)
Tff7b72def Td2a8ffcreate_sessionTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3configTb4b4b4)Tb4b4b4:
Te6edf3session_id Tff7b72= Te6edf3uuidTff7b72.Td2a8ffuuid4Tb4b4b4(Tb4b4b4)Tff7b72.Td2a8ffhex
Te6edf3session Tff7b72= Te6edf3RNSHSessionTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3session_idTb4b4b4, Te6edf3config Tff7b72or Tb4b4b4{Tb4b4b4}Tb4b4b4)
Tff7b72with Tff7b72selfTff7b72.Td2a8ff_lockTb4b4b4:
Tff7b72selfTff7b72.Td2a8ff_sessionsTb4b4b4[Te6edf3session_idTb4b4b4] Tff7b72= Te6edf3session
Tff7b72selfTff7b72.Td2a8ff_on_session_changeTb4b4b4(Te6edf3sessionTb4b4b4)
Tff7b72selfTff7b72.Td2a8ffsaveTb4b4b4(Tb4b4b4)
Tff7b72return Te6edf3session
Tff7b72def Td2a8ffremove_sessionTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3session_idTb4b4b4)Tb4b4b4:
Tff7b72with Tff7b72selfTff7b72.Td2a8ff_lockTb4b4b4:
Te6edf3session Tff7b72= Tff7b72selfTff7b72.Td2a8ff_sessionsTff7b72.Td2a8ffgetTb4b4b4(Te6edf3session_idTb4b4b4)
Tff7b72if Te6edf3session Tff7b72is Tff7b72NoneTb4b4b4:
Tff7b72raise Tf85149KeyErrorTb4b4b4(Ta5d6ff"Ta5d6ffSession not foundTa5d6ff"Tb4b4b4)
Te6edf3sessionTff7b72.Td2a8ffshutdownTb4b4b4(Tb4b4b4)
Tff7b72with Tff7b72selfTff7b72.Td2a8ff_lockTb4b4b4:
Tff7b72selfTff7b72.Td2a8ff_sessionsTff7b72.Td2a8ffpopTb4b4b4(Te6edf3session_idTb4b4b4, Tff7b72NoneTb4b4b4)
Tff7b72selfTff7b72.Td2a8ffsaveTb4b4b4(Tb4b4b4)
Tff7b72return Tff7b72True
Tff7b72def Td2a8ffstart_sessionTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3session_idTb4b4b4)Tb4b4b4:
Te6edf3session Tff7b72= Tff7b72selfTff7b72.Td2a8fffind_sessionTb4b4b4(Te6edf3session_idTb4b4b4)
Tff7b72if Te6edf3session Tff7b72is Tff7b72NoneTb4b4b4:
Tff7b72raise Tf85149KeyErrorTb4b4b4(Ta5d6ff"Ta5d6ffSession not foundTa5d6ff"Tb4b4b4)
Tff7b72return Te6edf3sessionTff7b72.Td2a8ffstartTb4b4b4(Tb4b4b4)
Tff7b72def Td2a8ffstop_sessionTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3session_idTb4b4b4)Tb4b4b4:
Te6edf3session Tff7b72= Tff7b72selfTff7b72.Td2a8fffind_sessionTb4b4b4(Te6edf3session_idTb4b4b4)
Tff7b72if Te6edf3session Tff7b72is Tff7b72NoneTb4b4b4:
Tff7b72raise Tf85149KeyErrorTb4b4b4(Ta5d6ff"Ta5d6ffSession not foundTa5d6ff"Tb4b4b4)
Tff7b72return Te6edf3sessionTff7b72.Td2a8ffstopTb4b4b4(Tb4b4b4)
Tff7b72def Td2a8ffsend_inputTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3session_idTb4b4b4, Te6edf3textTb4b4b4)Tb4b4b4:
Te6edf3session Tff7b72= Tff7b72selfTff7b72.Td2a8fffind_sessionTb4b4b4(Te6edf3session_idTb4b4b4)
Tff7b72if Te6edf3session Tff7b72is Tff7b72NoneTb4b4b4:
Tff7b72raise Tf85149KeyErrorTb4b4b4(Ta5d6ff"Ta5d6ffSession not foundTa5d6ff"Tb4b4b4)
Tff7b72return Te6edf3sessionTff7b72.Td2a8ffsend_inputTb4b4b4(Te6edf3textTb4b4b4)
Tff7b72def Td2a8ffoutput_sinceTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3session_idTb4b4b4, Te6edf3cursorTff7b72=T79c0ff0Tb4b4b4)Tb4b4b4:
Te6edf3session Tff7b72= Tff7b72selfTff7b72.Td2a8fffind_sessionTb4b4b4(Te6edf3session_idTb4b4b4)
Tff7b72if Te6edf3session Tff7b72is Tff7b72NoneTb4b4b4:
Tff7b72raise Tf85149KeyErrorTb4b4b4(Ta5d6ff"Ta5d6ffSession not foundTa5d6ff"Tb4b4b4)
Tff7b72tryTb4b4b4:
Te6edf3cursor Tff7b72= Tffa657intTb4b4b4(Te6edf3cursorTb4b4b4)
Tff7b72except Tf85149ExceptionTb4b4b4:
Te6edf3cursor Tff7b72= T79c0ff0
Tff7b72return Te6edf3sessionTff7b72.Td2a8ffoutput_sinceTb4b4b4(Tffa657maxTb4b4b4(T79c0ff0Tb4b4b4, Te6edf3cursorTb4b4b4)Tb4b4b4)
Tff7b72def Td2a8ffclear_outputTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3session_idTb4b4b4)Tb4b4b4:
Te6edf3session Tff7b72= Tff7b72selfTff7b72.Td2a8fffind_sessionTb4b4b4(Te6edf3session_idTb4b4b4)
Tff7b72if Te6edf3session Tff7b72is Tff7b72NoneTb4b4b4:
Tff7b72raise Tf85149KeyErrorTb4b4b4(Ta5d6ff"Ta5d6ffSession not foundTa5d6ff"Tb4b4b4)
Te6edf3sessionTff7b72.Td2a8ffclear_outputTb4b4b4(Tb4b4b4)
Tff7b72return Te6edf3sessionTff7b72.Td2a8ffto_dictTb4b4b4(Te6edf3include_output_tailTff7b72=Tff7b72TrueTb4b4b4)
Tff7b72def Td2a8ffshutdownTb4b4b4(Tff7b72selfTb4b4b4)Tb4b4b4:
Tff7b72with Tff7b72selfTff7b72.Td2a8ff_lockTb4b4b4:
Te6edf3sessions Tff7b72= Tffa657listTb4b4b4(Tff7b72selfTff7b72.Td2a8ff_sessionsTff7b72.Td2a8ffvaluesTb4b4b4(Tb4b4b4)Tb4b4b4)
Tff7b72for Te6edf3session Tff7b72in Te6edf3sessionsTb4b4b4:
Tff7b72with Te6edf3contextlibTff7b72.Td2a8ffsuppressTb4b4b4(Tf85149ExceptionTb4b4b4)Tb4b4b4:
Te6edf3sessionTff7b72.Td2a8ffshutdownTb4b4b4(Tb4b4b4)
Tff7b72selfTff7b72.Td2a8ffsaveTb4b4b4(Tb4b4b4)
Tff7b72def Td2a8ff_on_session_changeTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3sessionTb4b4b4)Tb4b4b4:
Te6edf3callback Tff7b72= Tff7b72selfTff7b72.Td2a8ff_change_callback
Tff7b72if Te6edf3callback Tff7b72is Tff7b72not Tff7b72NoneTb4b4b4:
Tff7b72with Te6edf3contextlibTff7b72.Td2a8ffsuppressTb4b4b4(Tf85149ExceptionTb4b4b4)Tb4b4b4:
Te6edf3callbackTb4b4b4(Te6edf3sessionTb4b4b4)
Tff7b72def Td2a8ff_on_session_outputTb4b4b4(Tff7b72selfTb4b4b4, Te6edf3sessionTb4b4b4, Te6edf3chunkTb4b4b4)Tb4b4b4:
Te6edf3callback Tff7b72= Tff7b72selfTff7b72.Td2a8ff_output_callback
Tff7b72if Te6edf3callback Tff7b72is Tff7b72not Tff7b72NoneTb4b4b4:
Tff7b72with Te6edf3contextlibTff7b72.Td2a8ffsuppressTb4b4b4(Tf85149ExceptionTb4b4b4)Tb4b4b4:
Te6edf3callbackTb4b4b4(Te6edf3sessionTb4b4b4, Te6edf3chunkTb4b4b4)
──────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────────